fa0a0f5f0f49324dbc5c0071c0143ce5cf0a235d,src/frontend/org/voltdb/rejoin/StreamSnapshotDataTarget.java,StreamSnapshotDataTarget,close,#,163

Before Change


         * could be called multiple times, because all tables share one stream
         * target
         */
        if (m_mb != null) {
            closeIO();
            /*
             * only join the out thread, once the socket is closed, the in
             * thread will terminate
             */
            m_outThread.join();
            VoltDB.instance().getHostMessenger().removeMailbox(m_mb.getHSId());
            m_mb = null;
        }

After Change


            m_bytesSent.addAndGet(compressedBytes.length);

            // release the mailbox and close the socket
            VoltDB.instance().getHostMessenger().removeMailbox(m_mb.getHSId());
            m_mb = null;

            m_closed = true;